// // db.js 
// var mysql = require('mysql')

// module.exports = {
//     query: function (sql, params, callback) {
//         //每次使用的时候需要创建链接，数据操作完成之后要关闭连接
//         var connection = mysql.createConnection({
//             host: '124.223.210.20', //数据库地址
//             port: '3306',//端口号
//             user: 'lyf',//用户名
//             password: 'Lyf0521Lyf',//密码
//             database: 'hospital'//数据库名称
//         })
//         connection.connect(function (err) {
//             if (err) {
//                 throw err
//             }
//             //开始数据操作
//             connection.query(sql, params, function (err, results, fields) {
//                 if (err) {
//                     throw err
//                 }
//                 console.log(results, fields, "hhhhhhhhhhhhhhhhhhh")
//                 //将查询出来的数据返回给回调函数
//                 callback &&
//                     callback(
//                         JSON.parse(JSON.stringify(results)),
//                         JSON.stringify(fields)
//                         // results,
//                         // fields
//                     )
//                 //停止链接数据库，必须在查询语句后，要不然一调用这个方法，就直接停止链接，数据操作就会失败
//                 connection.end(function (err) {
//                     if (err) {
//                         console.log('关闭数据库连接失败！')
//                         throw err
//                     }
//                 })
//             })
//         })
//     },
// }
const mysql = require("mysql")
module.exports = {
    query(sql, params, callback) {
        const connection = mysql.createConnection({
            host: '124.223.210.20', //数据库地址
            port: '3306',//端口号
            user: 'root',//用户名
            password: 'Lyf0521Lyf',//密码
            database: 'hospital',//数据库名称
            multipleStatements: true,// 允许同时请求多条 sql 语句
            timezone: 'utc' // 解决时区时间统一的问题
        })
        connection.connect(err => {
            if (err) {
                console.log("数据库连接失败！")
                throw err
            }
            //console.log("数据库连接成功！");
        })
        connection.query(sql, params, (err, results, fileds) => {
            if (err) {
                //console.log("数据库连接失败！")
                throw err
            }
            callback && callback(results, fileds)
        })
        connection.end(err => {
            if (err) {
                //console.log("数据库关闭失败！")
                throw err
            }
            //console.log("数据库关闭成功！")
        })
    }
}
